KAFKA_IMAGE?=quay.io/strimzi/kafka:0.40.0-kafka-3.7.0
CLUSTER_IP?=bi-kafka-kafka-bootstrap
CLUSTER_PORT?=9093
TOPIC?=my-test-topic

producer:
	kubectl run kafka-producer -ti \
		--image=${KAFKA_IMAGE} \
		--rm=true --restart=Never \
		-- bin/kafka-console-producer.sh --bootstrap-server ${CLUSTER_IP}:${CLUSTER_PORT} --topic ${TOPIC}

consumer:
	kubectl run kafka-consumer -ti \
		--image=${KAFKA_IMAGE} \
		--rm=true --restart=Never \
		-- bin/kafka-console-consumer.sh --bootstrap-server ${CLUSTER_IP}:${CLUSTER_PORT} --topic ${TOPIC} --from-beginning